// 使用 mysql 第三方模块，来处理 MySQL 服务器的连接
const mysql = require("mysql");

function query(sql, params = []) {
    return new Promise((resolve, reject) => {
        // 创建一个 TCP 连接
        const connection = mysql.createConnection({
            host: "localhost",
            port: 3306,
            user: "root",
            password: "root",
            database: "api-koa",
            debug: ["ComQueryPacket", "RowDataPacket"],
        });

        // 发送 SQL 语句
        connection.query(sql, params, function (error, results) {
            if (error) {
                reject(error);
            } else {
                resolve(results);
            }
        });

        // 关闭连接
        connection.end();
    });
}

module.exports = query;

// module.exports = function (sql, params) {
//     // Promise 就是用来封装异步的
//     // 当异步执行成功后，就调用 resolve 方法
//     // 当异步执行失败后，就调用 reject 方法
//     return new Promise((resolve, reject) => {

//     });
// };
